package com.yanfan.mq.service;

import com.yanfan.common.core.mq.DeviceReport;
import com.yanfan.common.core.mq.DeviceReportBo;

/**
 * 实现此接口可以获取到所有发送的消息
 */
public interface IMqttMessageService {

    /**
     * 接收设备推送的消息
     */
    default void message(DeviceReport message, String topicName) {

    }

    /**
     * 接收订阅下发的消息
     */
    default void subscribe(DeviceReport message, String topicName) {

    }

    /**
     * 接收订阅下发的消息
     */
    default void subscribe(DeviceReport message, String topicName, DeviceReportBo reportBo) {
        this.subscribe(message, topicName);
    }
}
